package com.wanxi.dao.message.impl;

import com.wanxi.dao.message.MessageDao;
import com.wanxi.domain.PageModel;
import com.wanxi.domain.message.MessageModel;
import com.wanxi.util.JDBC;

import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.List;

public class MessageDaoImpl {

    JDBC jdbc = new JDBC();
    //插入数据
    /*public int insert(MessageModel messageModel) {

        String sql = "insert into message (subject,user_email ,feedback,create_time) values(?,?,?,date_format(now(),\"%Y-%m-%d\"))";

        List<Object> data = new ArrayList<>();
        data.add(messageModel.getSubject());
        data.add(messageModel.getEmail());
        data.add(messageModel.getFeedback());

        int i = jdbc.insertUser(sql, data);

        return i;
    }*/

    //数据全查
    /*public List<MessageModel> selectAll(PageModel pageModel) {
        Integer curr = pageModel.getCurr();
        Integer limit = pageModel.getLimit();
        String sql = "select * from message limit ?,?";
        List<Object> data = new ArrayList<>();

        data.add((curr-1)*limit);
        data.add(limit);

        ResultSet all = jdbc.findAll(sql, data);
        List<MessageModel> list  = new ArrayList<>();
        while (true) {
            try {
                if (!all.next()) break;
                MessageModel messageModel = new MessageModel();
                messageModel.setSubject(all.getString("subject"));
                messageModel.setEmail(all.getString("user_email"));
                messageModel.setFeedback(all.getString("feedback"));
                messageModel.setId(all.getString("id"));
                messageModel.setEnable(all.getInt("enable"));

                list.add(messageModel);
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
        return list;
    }*/

  
    /*public int getCount() {
        String sql  = "select count(*) count from message";

        int count = jdbc.getCount(sql);

        return count;
    }
*/
    //将该条数据回复状态置为1
  
    public int updateById(String id) {
        String  sql = "update message set enable = 1 where id = ?";
        List<Object> lists = new ArrayList<>();
        lists.add(id);

        int num = jdbc.insertUser(sql, lists);

        return num;
    }

    //跟据id查询反馈信息
    /*public MessageModel findById(String id) {

        String sql = "select subject,user_email from message where id =?";

        List<Object> data = new ArrayList<>();
        data.add(id);

        ResultSet all = jdbc.findByID(sql, data);

        MessageModel messageModel = new MessageModel();
        try {
            all.next();
            messageModel.setSubject(all.getString("subject"));
            messageModel.setEmail(all.getString("user_email"));

        } catch (SQLException e) {
            e.printStackTrace();
        }

        return messageModel;
    }*/


}
